//package com.cbgolf.oa.manager;
//
//import android.util.Log;
//import com.cbgolf.oa.net.WebAPI;
//import com.cbgolf.oa.util.DataUtil;
//import io.socket.client.IO;
//import io.socket.client.IO.Options;
//import io.socket.client.Socket;
//import io.socket.emitter.Emitter;
//import io.socket.emitter.Emitter.Listener;
//import java.net.URISyntaxException;
//
///**
// * Created by lq on 2018/5/2.
// */
//
//public class WsIo {
//
//  Socket socket = null;
//
//  public static final String TAG = WsIo.class.getName() + "-----------";
//
//  public void init() {
//    IO.Options options = new Options();
//    options.forceNew = true;
//    String realm =
//        "http://test.cbgolf.cn/backend/messages/queue/messageNotify/" + DataUtil.getUserId();
//    options.path = realm;
//    String configUrl = new StringBuilder()
//        .append("ws://")
//        .append(WebAPI.IP)
//        .append(WebAPI.web_socket)
//        .toString();
//    try {
//      socket = IO.socket(configUrl, options);
//    } catch (URISyntaxException e) {
//      e.printStackTrace();
//    }
//    socket.on(Socket.EVENT_CONNECT, new Emitter.Listener() {
//      @Override
//      public void call(Object... args) {
//        socket.emit("foo", "hi");
//        socket.disconnect();
//        Log.e(TAG, "contented----");
//      }
//
//    }).on(Socket.EVENT_MESSAGE, new Emitter.Listener() {
//
//      @Override
//      public void call(Object... args) {
//        Log.e(TAG, "EVENT_MESSAGE----");
//      }
//
//    }).on(Socket.EVENT_DISCONNECT, new Emitter.Listener() {
//
//      @Override
//      public void call(Object... args) {
//        Log.e(TAG, "EVENT_DISCONNECT----");
//      }
//
//    }).on(Socket.EVENT_CONNECT_ERROR, new Listener() {
//      @Override
//      public void call(Object... args) {
//        Log.e(TAG, "EVENT_CONNECT_ERROR----");
//      }
//    }).on(Socket.EVENT_ERROR,new Emitter.Listener() {
//
//      @Override
//      public void call(Object... args) {
//        Log.e(TAG, "EVENT_ERROR----");
//      }
//    }).on(Socket.EVENT_RECONNECT_ERROR, new Listener() {
//      @Override
//      public void call(Object... args) {
//        Log.e(TAG, "EVENT_RECONNECT_ERROR----");
//      }
//    });
//    socket.connect();
//  }
//
//}
